package com.epic;

/**
 * use refresh metastore data
 * consumer kafka data to process data to metastore
 * write to avro to warehouse path,and refresh metastore data to pg
 */
public class Main {
    public static void main(String[] args) {
        // consume data record and operator refresh metastore to database
        //

    }
}
